package com.atguigu.edu.realtime.dws.app;

import com.atguigu.edu.realtime.common.base.BaseApp;
import com.atguigu.edu.realtime.common.base.BaseSqlApp;
import com.atguigu.edu.realtime.common.constant.Constant;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

public class DwsTradebodyOrderWindow extends BaseApp {
    public static void main(String[] args) {
        new DwsTradebodyOrderWindow().start(
                10086,
                4,
                "dws_tradebody_order_window",
                Constant.TOPIC_DWD_TRADE_ORDER_DETAIL
        );
    }

    @Override
    public void handle(StreamExecutionEnvironment env, DataStreamSource<String> kafkaStrDS) {
        kafkaStrDS.print();
    }
}
